package com.zdxk.msgPush.msg.subject;

import com.zdxk.msgPush.msg.observer.interfaces.IObserver;
import com.zdxk.msgPush.msg.subject.interfaces.ISubject;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public abstract class AbstractSubject implements ISubject {

    private Map<String,IObserver> observerMap = new ConcurrentHashMap<>();

    public Map<String, IObserver> getObserverMap() {
        return observerMap;
    }

    public void setObserverMap(Map<String, IObserver> observerMap) {
        this.observerMap = observerMap;
    }
}
